<?php

namespace app\index\controller;

use app\index\controller\job\TestQueue;
use think\Controller;
use think\Queue;

class JobTest extends Controller
{
    // 生产者，添加消息队列
    public function addQueue()
    {
        $age = rand(0,99);
        // 参数
        $data = [
            'age' => $age,
            'userName' => '一起摸鱼'.$age
        ];

        // 消息队列名
        $queuename = 'testQueue';

        // 推送到消息队列里面去,注意这里的 ::class 是PHP5.5才有的写法
        $isPushed = Queue::push(TestQueue::class,$data,$queuename);
        // PHP5.5以下的可以直接写命名空间
        // $isPushed = Queue::push('app\common\queue\TestQueue', $data, $queueName);

        if($isPushed !== false){
            // 成功之后的业务
            echo '队列加入成功';
        }else{
            // 失败之后的业务
            echo '队列加入失败';
        }
    }
}
